3e7ebf84f975729eb0735269b464b08cfedc7c6b,src/java/org/apache/cassandra/hadoop/pig/AbstractCassandraStorage.java,AbstractCassandraStorage,columnToTuple,#Column#CfDef#AbstractType#,120
Before Change
// value
Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef);
if (validators.get(col.name()) == null)
{
Map<MarshallerType, AbstractType> marshallers = getDefaultMarshallers(cfDef);
setTupleValue(pair, 1, cassandraToObj(marshallers.get(MarshallerType.DEFAULT_VALIDATOR), col.value()));
After Change
/** convert a column to a tuple */
protected Tuple columnToTuple(Column col, CfInfo cfInfo, AbstractType comparator) throws IOException
{
CfDef cfDef = cfInfo.cfDef;
Tuple pair = TupleFactory.getInstance().newTuple(2);
// name
if(comparator instanceof AbstractCompositeType)
setTupleValue(pair, 0, composeComposite((AbstractCompositeType)comparator,col.name()));
else
setTupleValue(pair, 0, cassandraToObj(comparator, col.name()));
// value
Map<ByteBuffer,AbstractType> validators = getValidatorMap(cfDef);
ByteBuffer colName;
if (cfInfo.cql3Table && !cfInfo.compactCqlTable)
{
ByteBuffer[] names = ((AbstractCompositeType) parseType(cfDef.comparator_type)).split(col.name());
colName = names[names.length-1];
}
else
colName = col.name();
if (validators.get(colName) == null)
{
Map<MarshallerType, AbstractType> marshallers = getDefaultMarshallers(cfDef);
setTupleValue(pair, 1, cassandraToObj(marshallers.get(MarshallerType.DEFAULT_VALIDATOR), col.value()));